package com.webchat.connect.messagequeue.consumer.rocketmq;

import org.apache.rocketmq.spring.core.RocketMQListener;

/**
 * 当前对话消息队列，因为需要WebSocket或SSE服务端主动推送，为了解决分布式websocketsession及ssemetter共享问题，这里必须广播模式
 */
//@Component
//@RocketMQMessageListener(consumerGroup = "web_chat",
//                         topic = "queue_message_card_push",
//                         messageModel = MessageModel.BROADCASTING)
public class MessageCardPushRocketQueueConsumer implements RocketMQListener<String> {
//
//    @Autowired
//    private MessageCardPushConsumeService messageCardPushConsumeService;
//
    /**
     * 处理来自IM 对话相关消息
     *
     * @param message
     */
    @Override
    public void onMessage(String message) {

//        messageCardPushConsumeService.consume(message);
    }
}